package com.personal.gateway.service;

import com.personal.gateway.entity.FlinkCommandHistory;
import com.personal.gateway.entity.FlinkGatewayRoute;

import java.util.List;
import java.util.concurrent.ExecutionException;

/**
 * @program: FlinkGateway
 * @description:
 * @author: yangliao
 * @create: 2021-08-23
 */
public interface FlinkConfigService {

    String edit(FlinkGatewayRoute route) throws ExecutionException, InterruptedException;

    String alarmEdit(FlinkGatewayRoute route) throws ExecutionException, InterruptedException;

    FlinkGatewayRoute getProjectById(Integer id);

    String del(Integer id, String user);

    String routeView() throws ExecutionException, InterruptedException;

    List<FlinkCommandHistory> history(Integer id);

    FlinkCommandHistory getHistoryById(Integer id);

}
